/*
 * 文件名：Database.java
 * 版权：亚信科技(南京)版权所有
 * 描述：TODO
 * 修改人：huangxd2
 * 修改时间：2014年11月2日
 * 修改内容：TODO
 */
package com.ailk.bigdata.etl.realstream.server;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.ailk.bigdata.etl.realstream.server.dao.RealStreamUnitDao;
import com.ailk.bigdata.etl.realstream.server.dao.impl.RealStreamUnitDaoPGImpl;
import com.ailk.bigdata.etl.realstream.server.model.RealStreamUnit;
import com.ailk.bigdata.etl.realstream.server.model.Table;

/**
 * @description TODO
 * @author [huangxd2]
 * @version [版本号,2014年11月2日]
 * @see [相关类/方法]
 * @since [产品/模块版本]
 */
public class Database
{
	// 表信息，key为only_unit_code
	private static Map<Long, Table> tables = new HashMap<Long, Table>();

	// dao实现类
	private RealStreamUnitDao realStreamUnitDao = new RealStreamUnitDaoPGImpl();

	public void initDatabase()
	{
		List<RealStreamUnit> allUnit = realStreamUnitDao.getAllUnit();
		for (RealStreamUnit unit : allUnit)
		{
			tables.put(unit.getOnlyUnitCode(), unit.getTable());
		}
	}
}
